/*
 * audio_capture_pipewire.c - PipeWire audio capture fallback
 * 
 * Works on modern Linux distributions where PipeWire is the default audio server.
 * Fedora 40+, Ubuntu 24.04+, Arch, etc.
 * 
 * Uses pw_stream for simple, non-blocking audio capture.
 */

#include "../include/rootstream.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <stdint.h>
#include <errno.h>
#include <unistd.h>

#ifdef HAVE_PIPEWIRE
#include <pipewire/pipewire.h>
#include <pipewire/type.h>
#include <spa/param/audio/format.h>
#include <spa/param/props.h>
#include <spa/utils/result.h>

typedef struct {
    struct pw_loop *loop;
    struct pw_stream *stream;
    struct pw_core *core;
    struct pw_context *context;
    
    int16_t *buffer;
    size_t buffer_size;
    size_t read_pos;
    
    int sample_rate;
    int channels;
    int frame_size;
} pipewire_capture_ctx_t;

/* Stream events callback */
static void on_process(void *userdata) {
    pipewire_capture_ctx_t *pw = (pipewire_capture_ctx_t *)userdata;
    struct pw_buffer *b;
    struct spa_buffer *buf;

    if ((b = pw_stream_dequeue_buffer(pw->stream)) == NULL) {
        return;
    }

    buf = b->buffer;
    
    /* Get audio data from buffer */
    for (int i = 0; i < buf->n_datas; i++) {
        struct spa_data *d = &buf->datas[i];
        
        if (d->data == NULL) continue;
        
        uint32_t n_samples = d->chunk->size / sizeof(int16_t);
        int16_t *samples = (int16_t *)d->data;
        
        /* Copy to our buffer */
        if (pw->read_pos + n_samples <= pw->buffer_size) {
            memcpy(pw->buffer + pw->read_pos, samples, 
                   n_samples * sizeof(int16_t));
            pw->read_pos += n_samples;
        }
    }

    pw_stream_queue_buffer(pw->stream, b);
}

static const struct pw_stream_events stream_events = {
    PW_VERSION_STREAM_EVENTS,
    .process = on_process,
};

/*
 * Initialize PipeWire audio capture
 */
int audio_capture_init_pipewire(rootstream_ctx_t *ctx) {
    pipewire_capture_ctx_t *pw = calloc(1, sizeof(pipewire_capture_ctx_t));
    if (!pw) {
        fprintf(stderr, "ERROR: Memory allocation failed\n");
        return -1;
    }

    pw->sample_rate = 48000;
    pw->channels = 2;
    pw->frame_size = 240;  /* 5ms at 48kHz */
    pw->buffer_size = pw->frame_size * pw->channels * 4;  /* 4 frames buffer */

    pw->buffer = calloc(pw->buffer_size, sizeof(int16_t));
    if (!pw->buffer) {
        free(pw);
        return -1;
    }

    pw->read_pos = 0;

    /* Initialize PipeWire */
    pw_init(NULL, NULL);

    /* Create main loop */
    pw->loop = pw_loop_new(NULL);
    if (!pw->loop) {
        fprintf(stderr, "ERROR: Cannot create PipeWire main loop\n");
        free(pw->buffer);
        free(pw);
        return -1;
    }

    /* Create context */
    pw->context = pw_context_new(pw->loop, NULL, 0);
    if (!pw->context) {
        fprintf(stderr, "ERROR: Cannot create PipeWire context\n");
        pw_loop_destroy(pw->loop);
        free(pw->buffer);
        free(pw);
        return -1;
    }

    /* Create core and connect */
    pw->core = pw_context_connect(pw->context, NULL, 0);
    if (!pw->core) {
        fprintf(stderr, "ERROR: Cannot connect to PipeWire core\n");
        pw_context_destroy(pw->context);
        pw_loop_destroy(pw->loop);
        free(pw->buffer);
        free(pw);
        return -1;
    }

    /* Create stream */
    pw->stream = pw_stream_new_simple(
        pw->loop,
        "RootStream Capture",
        pw_properties_new(
            PW_KEY_MEDIA_TYPE, "Audio",
            PW_KEY_MEDIA_CATEGORY, "Capture",
            PW_KEY_AUDIO_FORMAT, "S16LE",
            NULL
        ),
        &stream_events,
        pw
    );

    if (!pw->stream) {
        fprintf(stderr, "ERROR: Cannot create PipeWire stream\n");
        pw_core_disconnect(pw->core);
        pw_context_destroy(pw->context);
        pw_loop_destroy(pw->loop);
        free(pw->buffer);
        free(pw);
        return -1;
   ...

</details>



<!-- START COPILOT CODING AGENT SUFFIX -->

*This pull request was created from Copilot chat.*
>

<!-- START COPILOT CODING AGENT TIPS -->
---

💬 We'd love your input! Share your thoughts on Copilot coding agent in our [2 minute survey](https://gh.io/copilot-coding-agent-survey).